package com.etl.dataflow.executor.core;

import com.etl.dataflow.common.entity.JdbcProperties;

/**
 * @author dx
 * @since 2022/6/15
 **/
abstract public class WriterFactory {
    /**
     * 获取数据库写入器
     *
     * @param dstTableName     目标表名
     * @param writerProperties jdbc参数
     * @param transporter      缓冲器
     * @return 数据库写入器
     */
    abstract public Writer getWriter(String dstTableName, JdbcProperties writerProperties, Transporter transporter);
}
